package io.mqttpush.mqttclient.conn;

import io.netty.handler.codec.mqtt.MqttQoS;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class UnLoginTask {

	
	
	
	protected static class TopicAndQos{
		
		public String topicName;
		public MqttQoS mqttQoS;
		public TopicAndQos(String topicName, MqttQoS mqttQoS) {
			super();
			this.topicName = topicName;
			this.mqttQoS = mqttQoS;
		}
		
		
		
	}
	
	
	protected static class TopicMsg extends TopicAndQos{

		public byte[] bs;
		
		public TopicMsg(String topicName, MqttQoS mqttQoS) {
			super(topicName, mqttQoS);
			
		}

		public TopicMsg(String topicName, MqttQoS mqttQoS, byte[] bs) {
			super(topicName, mqttQoS);
			this.bs = bs;
		}
		
		
	}
	


	public static final List<TopicAndQos> topics=new ArrayList<>(8);
	
	
	public static final BlockingQueue<String> untopics=new LinkedBlockingQueue<>(8);
	
	
	public static final BlockingQueue<TopicMsg> unLoginMsg=new LinkedBlockingQueue<>(8);
}
